package com.yanqu.road.server.manager.tomb.service;

import com.google.protobuf.AbstractMessage;
import com.google.protobuf.InvalidProtocolBufferException;
import com.yanqu.road.pb.syncMessage.SyncMessage;
import com.yanqu.road.pb.tomb.Tomb;
import com.yanqu.road.server.command.ICrossServiceCommand;
import com.yanqu.road.server.manager.tomb.TombServiceMgr;


import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CompletableFuture;

public class TombChangeSwitchCmd implements ICrossServiceCommand {
    @Override
    public CompletableFuture<AbstractMessage.Builder<?>> execute(SyncMessage.Request request, int activityId, int groupId) throws InvalidProtocolBufferException {
        Tomb.TombUpdateAutoEventSwitchReqMsg reqMsg = Tomb.TombUpdateAutoEventSwitchReqMsg.parseFrom(request.getDataBytes());
        List<Integer> switchList = new ArrayList<>();
        switchList.addAll(reqMsg.getOpenSwitchTypeList())  ;
        long userId = request.getSenderId();
        //int activityId = request.getActivityId();
        CompletableFuture<AbstractMessage.Builder<?>> completableFuture = new CompletableFuture<>();
        completableFuture.complete(TombServiceMgr.updateTakeCareSwitch(activityId,userId,switchList));
        return completableFuture;



    }
}
